package com.star.spring.rocketmq.annotation;

import java.lang.annotation.*;

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface OnMessage {
    
    /**
     * 消费者组
     */
    String consumerGroup();
    
    /**
     * 主题
     */
    String topic();
    
    /**
     * 标签，默认为 "*" 表示接收所有标签
     */
    String tag() default "*";
}